package com.innodealing.offsetskip.config;

import org.springframework.boot.context.properties.ConfigurationProperties;

import java.util.HashMap;
import java.util.Map;

/**
 * Kafka Offset Skip 配置属性
 * 
 * 该类用于配置 Kafka 消息跳过功能的相关参数
 */
@ConfigurationProperties(prefix = "kafka.offset-skip")
public class KafkaOffsetSkipProperties {
    /**
     * key格式: groupId.topic.partition
     * value: 要跳过的 offset
     */
    private Map<String, Long> config = new HashMap<>();


    public Map<String, Long> getConfig() {
        return config;
    }

    public void setConfig(Map<String, Long> config) {
        this.config = config;
    }
}